package com.gasq.community.message.kafka.basemessageentity;

/**
 * Created by mjh on 2017/1/6.
 */
public interface MessageEntityCallback<T> {

      String getDataType();

     Class<T> getDataTypeClass();

    void onMessage(MessageEntity<T> messageEntity);
}
